package com.guandata.cdc.model.sink.sink_table_name_strategy;

import com.guandata.cdc.model.sink.SinkTableNameStrategy;
import org.apache.flink.api.java.utils.ParameterTool;

public class CustomSinkTableNameStrategy implements SinkTableNameStrategy  {
    private final String customTableName;

    public CustomSinkTableNameStrategy(ParameterTool params) {
        this.customTableName = params.getRequired("sink.table.name");
    }

    @Override
    public String getSinkTableName() {
        return customTableName;
    }
}
